package com.distributed.netty.encode;

import com.distributed.netty.entity.Message;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;

/**
 * @desc	将对象编码	
 * @author	高增源
 * @time	2021年11月18日
 */
public class MessageEncoder extends MessageToByteEncoder<Message> {

	@Override
	protected void encode(ChannelHandlerContext ctx, Message msg, ByteBuf out) throws Exception {
		System.err.println("编码中……"+msg);

		if (msg==null) {
			return;
		}
		byte[] bs = ByteUtils.objectToByty(msg);
		out.writeBytes(bs);
		ctx.flush();
	}
	
}
